70213b51db417212955807d18218156f5e523550,app/oryx-app/src/main/java/com/cloudera/oryx/app/speed/rdf/RDFSpeedModelManager.java,RDFSpeedModelManager,consume,#Iterator#Configuration#,73
Before Change
throws IOException {
while (updateIterator.hasNext()) {
KeyMessage<String,String> km = updateIterator.next();
String key = km.getKey();
String message = km.getMessage();
Objects.requireNonNull(key, "Bad message: " + km);
switch (key) {
case "UP":
// Nothing to do; just hearing our own updates
After Change
throws IOException {
while (updateIterator.hasNext()) {
KeyMessage<String,String> km = updateIterator.next();
String key = Objects.requireNonNull(km.getKey(), "Bad message: " + km);
String message = km.getMessage();
switch (key) {
case "UP":